package com.sfx.messagequeue.common.arguments;

import com.sfx.messagequeue.common.consumer.Consumer;

import java.io.Serializable;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: sfx
 * Date: 2023-08-11
 * Time: 16:15
 */
public class BasicConsumeArguments extends BasicArguments implements Serializable {

    private String consumerTag;
    private String queueName;
    private boolean autoAck;

    //不需要消费者的回调,网络传输不能传输回调函数.
    //服务器Broker并不关心订阅者拿到消息要干什么,只需要将
    //把消息传递给消费者即可.
    // 所以我们服务器这里只需要一个固定的回调,即每次把消息传递给消费者就可以了
    //固定回调
    private Consumer consumer;

    public String getConsumerTag() {
        return consumerTag;
    }

    public void setConsumerTag(String consumerTag) {
        this.consumerTag = consumerTag;
    }

    public String getQueueName() {
        return queueName;
    }

    public void setQueueName(String queueName) {
        this.queueName = queueName;
    }

    public boolean isAutoAck() {
        return autoAck;
    }

    public void setAutoAck(boolean autoAck) {
        this.autoAck = autoAck;
    }
}